package com.boot.study.consumer;


import com.boot.study.stream.AbstractStreamMessageListener;
import com.boot.study.message.SameasDelMessage;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;


@Component
@Slf4j
public class SameasDelConsumer  extends AbstractStreamMessageListener<SameasDelMessage> {

    @Override
    public void onMessage(SameasDelMessage message) {
        log.info("[onMessage][收到 删除消息]",message.getIdList().toString());


    }
}
